ca4dc791cd54df31e6582839f63e30ff4961593c,test/freenet/client/async/SplitFileInserterStorageTest.java,SplitFileInserterStorageTest,testRepeatedEncodeAfterShutdownCrossSegment,#number#,768
Before Change
// Has not encoded anything.
for(SplitFileInserterSegmentStorage segment : storage.segments)
assert(!segment.isFinishedEncoding());
SplitFileInserterStorage resumed = new SplitFileInserterStorage(storage.getRAF(), data, cb, r,
memoryLimitedJobRunner, jobRunner, ticker, keys, fg, persistentFileTracker);
resumed.start();
// The memoryLimitedJobRunner will only encode one segment at a time.
// Wait for it to encode one segment.
memoryLimitedJobRunner.shutdown();
After Change
SplitFileInserterStorage resumed = null;
if(storage.crossSegments != null) {
for(int i=0;i<storage.crossSegments.length;i++) {
memoryLimitedJobRunner = new MemoryLimitedJobRunner(9*1024*1024L, 1, executor);
resumed = new SplitFileInserterStorage(storage.getRAF(), data, cb, r,
memoryLimitedJobRunner, jobRunner, ticker, keys, fg, persistentFileTracker);
assertEquals(i, countEncodedCrossSegments(resumed));
resumed.start();
// The memoryLimitedJobRunner will only encode one segment at a time.
// Wait for it to encode one segment.
memoryLimitedJobRunner.shutdown();